package com.bigdata.spark.core.test

/**
 * @author Gerry chan
 * @version 1.0
 * 相当于RDD分解后的task
 */
class SubTask extends  Serializable {
  var datas:List[Int] = _
  var logic:(Int)=>Int = _

  //计算
  def compute():List[Int] = {
    datas.map(logic)
  }

}
